package cn.yi.boot.mq.demo;

import cn.yi.boot.mq.rocketmq.message.handler.AbstractMessageHandler;
import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import com.alibaba.rocketmq.common.message.MessageExt;
import org.springframework.stereotype.Component;

import java.util.Map;

@Component("Pay")
public class PayMessageHandler extends AbstractMessageHandler {
    @Override
    public ConsumeConcurrentlyStatus process0(Map<String, Object> data, MessageExt msg, ConsumeConcurrentlyContext context) {
        return null;
    }
}
